package direct;

import com.rabbitmq.client.*;
import util.RabbitUtil;

import java.io.IOException;

public class Costomer1 {

  public static void main(String[] args) throws IOException {

    String exchangeName = "logs_direct";

    Connection connection = RabbitUtil.getConnection();
    Channel channel = connection.createChannel();
    //通道声明交换机以及交换的类型
    channel.exchangeDeclare(exchangeName ,"direct");
    //创建一个临时队列
    String queue = channel.queueDeclare().getQueue( );
    //基于routekey绑定队列和交换机
    channel.queueBind(queue, exchangeName,"error");

    channel.basicConsume(queue,true,new DefaultConsumer(channel){
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
        System.out.println("消费者1：" + new String(body));
      }
    });

  }
}
